package com.example;


import java.util.List;

import rx.Observable;
import rx.functions.Action1;
import rx.functions.Func1;

public class RxJavaTest {

    //
    /**
     * @param arg
     * 使用RxJava
     */
    public static void main(String[] arg){

//     1、   使用Map操作符来进行对象转换
        Observable.just("Hello, world!")
                .map(new Func1<String, String>() {
                    @Override
                    public String call(String s) {
                        return s + " -Dan";
                    }
                })
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        System.out.println(s);

                    }
                });

//        ()->{}这个奇怪的符号表示lambda函数。函数类型不需要申明，可以由接口的方法签名自动推导出来，对于上面的lambda函数：

    }

}
